package com.ky.pro.java.mq.service;

public interface MessagingService {

    /**
     * 发送消息到p2p队列
     * @param queueId
     * @return
     */
    boolean sendToQueue(String queueId, String message);

    /**
     * 发布消息到主题
     * @param topic
     * @return
     */
    boolean publish(String topic, String message);

    /**
     * 监听p2p队列消息
     * @param queueId
     * @param listener
     * @return
     */
    boolean receiveFromQueue(String queueId, IMessageListener listener);

    /**
     * 订阅主题
     * @param topic
     * @param listener
     * @return
     */
    boolean subscribe(String topic, IMessageListener listener);

}
